createRouteBuilder{
    @Override public void configure() throws Exception {
      from("direct:start").to(neo4jEndpoint).process(new Processor(){
        @Override public void process(        Exchange arg0) throws Exception {
          Long id=(Long)arg0.getIn().getHeader(Neo4jEndpoint.HEADER_NODE_ID);
          assertNotNull(id);
}
configure{
  from("direct:start").to(neo4jEndpoint).process(new Processor(){
    @Override public void process(    Exchange arg0) throws Exception {
      Long id=(Long)arg0.getIn().getHeader(Neo4jEndpoint.HEADER_NODE_ID);
      assertNotNull(id);
}
process{
  Long id=(Long)arg0.getIn().getHeader(Neo4jEndpoint.HEADER_NODE_ID);
  org.springframework.data.neo4j.rest.SpringRestGraphDatabase.getNodeById
}
testCreateNodes{
  final int messageCount=100;
  end.expectedMessageCount(messageCount);
    @Override public void run(){
      for (int k=0; k < messageCount; k++) {
        template.sendBodyAndHeader(null,Neo4jEndpoint.HEADER_OPERATION,Neo4jOperation.CREATE_NODE);
  end.assertIsSatisfied();
}
run{
  for (int k=0; k < messageCount; k++) {
}
